let eventEmitter = require('../eventEmitter');

const startRealTime = io => {
// 当连接开始的时候触发
  io.on('connection', client => {
    console.log('开始链接');
    // 当被连接的这台客户端开始发送了一个开始实时的信号

    client.on( 'startRealTime', () => {
       console.log('收到客户端的开启命令');
      // 订阅 新增有效订单事件
      // 监听一个订单事件, 发生订单后就像客户端发送

      // 新增一条动态
      eventEmitter.on( 'newMoment', info  => {
        client.emit( 'newMoment', info );
      });

      // 赏金池信息更新
      eventEmitter.on( 'money', info  => {
        client.emit( 'money', info );
      });

  } );
  });


// 监听某个端口
  let port = 8000;

  io.listen( port );

};


 module.exports = startRealTime;